package org.yzh.web.business.kafka.consumer;

import org.springframework.stereotype.Component;

@Component
public class Consumer4Kafka {
//
//    @KafkaListener(topics = {"gwdTest"}, groupId = "mentugroup")
//    public void listener(ConsumerRecord<String, String> record) {
//        //获取消息
//        String message = record.value();
//        //消息偏移量
//        long offset = record.offset();
//        System.err.println("读取的消息：" + message + "\n当前偏移量：" + offset);
//    }
}
